package cn.zwx.common.rocket.producer.service.Impl;

import cn.zwx.common.rocket.consumer.bo.ConsumerListenerBO;
import cn.zwx.common.rocket.consumer.enums.ReturnCodeEnum;
import cn.zwx.common.rocket.producer.service.DefaultConsumerService;
import com.alibaba.fastjson.JSON;
import org.springframework.stereotype.Service;

@Service
public class OrderConsumerServiceImpl implements DefaultConsumerService {
    @Override
    public String getTopic() {
        return "user_order_topic";
    }

    @Override
    public String process(ConsumerListenerBO bo) {
        System.out.println("接口到消息："+JSON.toJSONString(bo));
        return ReturnCodeEnum.SUCCESS.getCode();
    }
}
